package com.doit.hbase.client;

import com.doit.hbase.utils.HbaseUtils;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;

/**
 * @DATE 2021/12/13/15:10
 * @Author MDK
 * @Version 2021.2.2
 **/
public class C06_CreateTable01 {
    public static void main(String[] args) throws Exception {
        Connection conn = HbaseUtils.getConnection();
        Admin admin = HbaseUtils.getAdmin(conn);

        //建表  create 'tb_order' ,  'cf'
        /*
        * 1.表描述器构建器  构件 表描述器
        *   2.表描述器构建器
        *   列族描述器构建器  构建  列族描述器
        *   列族描述器构建器
        * */
        TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(TableName.valueOf("tb_order"));

        //添加列族
        ColumnFamilyDescriptorBuilder columnFamilyDescriptorBuilder = ColumnFamilyDescriptorBuilder.newBuilder("cf1".getBytes());
        ColumnFamilyDescriptor columnFamilyDescriptor = columnFamilyDescriptorBuilder.build();

        //列族描述器构建器  构建  列族描述器
        tableDescriptorBuilder.setColumnFamily(columnFamilyDescriptor);
        TableDescriptor tableDescriptor = tableDescriptorBuilder.build();

        //建表
        admin.createTable(tableDescriptor);
        admin.close();
        conn.close();
    }
}
